package com.gitee.theskyzero.data.kafka;

import org.springframework.context.annotation.Bean;
import org.springframework.kafka.listener.ErrorHandler;
import org.springframework.kafka.listener.SeekToCurrentErrorHandler;

public class KafkaCustomConfiguration {


    @Bean
    ErrorHandler errorHandler() {
        return new SeekToCurrentErrorHandler();
    }

}
